// 引入mysql数据库
const mysql = require('mysql');

// 连接池
let pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: '123456',
    database: 'gameData',
    port: 3306
})

// 封装一个函数，用于执行sql语句
function query(sql, params) {
    return new Promise((resolve, reject) => {
        pool.getConnection((err, connection) => {
            if (err) {
                reject(err);
            } else {
                connection.query(sql, params, (err, results) => {
                    connection.release(); // 释放连接
                    if (err) {
                        reject(err);
                    } else {
                        resolve(results); // 返回查询结果
                    }
                });
            }
        });
    }).catch(err => {
        try {
            console.error('Error caught:', err);
        } catch (innerError) {
            console.error('Error in catch handler:', innerError);
        }
    });
}

module.exports = {
    query
}